#*********************************************************************************
# ** 文件名称：sqoop_mysql_hdfs.sh
# ** 功能描述：通过sqoop把mysql数据导入hdfs
# ** 创建者：xiaoxu
# ** 修改日期：19-06-13
# ** 修改人：gxd
# ** 修改内容:kaoshi
#*********************************************************************************
#!/usr/bin/env bash

DAT=`date -d '-1 day' "+%Y-%m-%d"`
sysdate=` date  "+%Y-%m-%d" `

#如果有参数传入，重跑脚本时使用（06-13号跑06-09的任务时）
#./sqoop_mysql_hdfs.sh 1 2 3 脚本传入的参数为1 2 3，参数之间用空格间隔
#$1代表执行脚本时，传入的第一个参数 $n,第n个参数
if [ $1 ]; then
  DAT=$1
fi

echo "${DAT}"


/home/gxd/app/sqoop-1.4.6-cdh5.7.0/bin/sqoop import \
         --connect jdbc:mysql://192.168.180.133:3306/shop?zeroDateTimeBehavior=convertToNull \
         --username root \
         --password root \
         --table mmall_order -m -1 \
         --fields-terminated-by ',' \
         --delete-target-dir \
         --target-dir "/user/exam/bdm_exam.db/mmall_order/day=${DAT}"

/home/gxd/app/sqoop-1.4.6-cdh5.7.0/bin/sqoop import \
     --connect jdbc:mysql://192.168.180.133:3306/shop?zeroDateTimeBehavior=convertToNull \
     --username root \
     --password root \
     --table mmall_order_item -m -1 \
     --fields-terminated-by ',' \
     --delete-target-dir \
     --target-dir "/user/exam/bdm_exam.db/mmall_order_item/day=${DAT}"

/home/gxd/app/sqoop-1.4.6-cdh5.7.0/bin/sqoop import \
     --connect jdbc:mysql://192.168.180.133:3306/shop?zeroDateTimeBehavior=convertToNull \
     --username root \
     --password root \
     --table mmall_shipping -m -1 \
     --fields-terminated-by ',' \
     --delete-target-dir \
     --target-dir "/user/exam/bdm_exam.db/mmall_shipping/day=${DAT}"